/**
 * 
 */
package com.oppo.db;

import java.sql.SQLException;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.ResultSetHandler;

/**
 * @author 天下有雪
 *
 */
public class BasicDataOperation {
	// 测试数据库连接是否正常
	// 创建一个queryrunner类 -- 等价于jdbc的statement查询器
	QueryRunner qr = new QueryRunner(DBCPDataSource.getDataSource(), true); // 第二个参数是支持sql语句中使用占位符
	
	/**
	 * @功能描述:查询操作
	 */
	public <T> T queryData(String strsql, ResultSetHandler<T> rsh, Object... params) {
		T t = null;
		// 进行查询操作
		try {
			t = qr.query(strsql, rsh, params);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return t;
	}
	/**
	 * @功能描述:增删改操作
	 */
	public int updateData(String strSql, Object... params) {
		int i = 0;
		try {
			i = qr.update(strSql, params);// 进行修改、新增、删除操作
		} catch (Exception e) {
			System.out.println("更新操作异常：" + e.getMessage());// 查询操作异常
			e.printStackTrace();
		}
		return i;
	}
}
